spring webflux Spring Webflux + Reactive Kafka (1) - Producer 개인적인 토이 프로젝트로 Spring Webflux & Reactive Kafka를 활용하여 API를 통한 프로듀서와 컨슈머를 구성해보려 한다. 단순히 RestController를 통해 들어온 메시지를 카프카로 전송하고 컨슈머는 카프카에서 메시지를 가져오기만 하는 굉장히 단순한 흐름이다. 주키퍼와 브로커는 각 1대씩으로 우선 구성하였고 2대 이상 클러스터는 차후 시간날때 구성하려 한다. Co... SpringreactivekafkaReactive KafkaJavaspring webfluxwebfluxSpring bootJava [Spring WebFlux] Reactive Streams란 라이브러리 및 프레임워크에 상관없이 데이터 스트림을 비동기로 다룰 수 있는 공통 메커니즘이며, 이 메커니즘을 편리하게 사용할 수 있는 인터페이스 제공 Publisher : 데이터를 만들어 통지하는 생산자 Subscriber : 데이터를 받아 처리하는 소비자 Publisher와 Subscriber는 아래 4개의 프로토콜로 데이터를 통지함 onSubscribe : 데이터 통지가 준비됐음을 통지 ... Reactive Streamsspring webfluxReactive Streams 급하게 RestTemplate를 대체 하기 위한 Spring WebFlux WebClient 사용설명서 - WebClient HTTP Method별 사용 [File Download(다운로드), Upload(업로드) 포함] MediaType.APPLICATION_JSON MSA 서버 통신간 가장 기본적인 조회 방식으로 앞서 WebClient Bean에 BaseUrl를 설정하였기 때문에 이후에 정의되는 path, PathVariable, RequestParam를 UriBuilder를 통해 쉽게 정의할 수 있으며 따로 UriEncoder로 문자열을 치환할 필요 없다. 이후 bodyToMono 메소드에 리턴 받을 C... SpringwebclientSpring bootRestTemplatespring webfluxRestTemplate
Spring Webflux + Reactive Kafka (1) - Producer 개인적인 토이 프로젝트로 Spring Webflux & Reactive Kafka를 활용하여 API를 통한 프로듀서와 컨슈머를 구성해보려 한다. 단순히 RestController를 통해 들어온 메시지를 카프카로 전송하고 컨슈머는 카프카에서 메시지를 가져오기만 하는 굉장히 단순한 흐름이다. 주키퍼와 브로커는 각 1대씩으로 우선 구성하였고 2대 이상 클러스터는 차후 시간날때 구성하려 한다. Co... SpringreactivekafkaReactive KafkaJavaspring webfluxwebfluxSpring bootJava [Spring WebFlux] Reactive Streams란 라이브러리 및 프레임워크에 상관없이 데이터 스트림을 비동기로 다룰 수 있는 공통 메커니즘이며, 이 메커니즘을 편리하게 사용할 수 있는 인터페이스 제공 Publisher : 데이터를 만들어 통지하는 생산자 Subscriber : 데이터를 받아 처리하는 소비자 Publisher와 Subscriber는 아래 4개의 프로토콜로 데이터를 통지함 onSubscribe : 데이터 통지가 준비됐음을 통지 ... Reactive Streamsspring webfluxReactive Streams 급하게 RestTemplate를 대체 하기 위한 Spring WebFlux WebClient 사용설명서 - WebClient HTTP Method별 사용 [File Download(다운로드), Upload(업로드) 포함] MediaType.APPLICATION_JSON MSA 서버 통신간 가장 기본적인 조회 방식으로 앞서 WebClient Bean에 BaseUrl를 설정하였기 때문에 이후에 정의되는 path, PathVariable, RequestParam를 UriBuilder를 통해 쉽게 정의할 수 있으며 따로 UriEncoder로 문자열을 치환할 필요 없다. 이후 bodyToMono 메소드에 리턴 받을 C... SpringwebclientSpring bootRestTemplatespring webfluxRestTemplate